package com.Reactor3参考文档;

import org.junit.Test;

import reactor.core.publisher.Flux;

public class Log {

	@Test
	public void test(){
		Flux<Integer> flux = Flux.range(1, 10)
                .log()
                .take(3);
		flux.subscribe();
	}

}
